package com.qf.rabbit.work;

import com.qf.rabbit.utils.ConnectionUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.TimeoutException;

public class Sender {

    public static void main(String[] args) throws Exception {
        Connection connection = ConnectionUtil.getConnection();
        Channel channel = connection.createChannel();
        //为了防止队列还没有存在,导致消息发送失败,所以所有的地方都要先声明队列
        //参数 1 队列的名字, 参数 2 是否持久化保存队列. 参数 3 是否排外,排外后不可同时访问, 参数 4 自动删除,如果队列的消息消费完成并且连接都断开了会自动删除, 参数 5 其他参数
        channel.queueDeclare("bk2105", true, false, false, null);
        for (int i=0;i<100;i++){

            channel.basicPublish("","bk2105",null,("可惜都不是你们的"+i).getBytes(StandardCharsets.UTF_8));

        }
    }
}
